package dataSource

import "gitee.com/zhucheer/orange/queue"

type MqInit struct {

}

func (mqInit *MqInit) NewMqInit() queue.MqProducer{
	mqProducerClient := queue.RegisterRocketProducerMust([]string{"127.0.0.1:9876"}, "test", 1)

	return mqProducerClient
}